package com.ddxz.flink.filter

import org.apache.flink.api.common.functions.FilterFunction

object NoneFilter extends FilterFunction[String]{
  override def filter(value: String): Boolean = {
    value == null
  }
}
